package com.tanjor.kafka.consumer;

public interface KafkaConsumerService {

	/**
	 * 消费者端处理业务代码
	 * @param value
	 */
	public void prosessMsg(String value);
}
